package com.yanxu.threadpool;

import java.util.concurrent.RejectedExecutionHandler;
import java.util.concurrent.ThreadPoolExecutor;

/**
 * @author 折戟沉沙铁未销
 * @version V1.0
 * @date 2025/3/9-2025
 * @Description: 这里用一句话描述这个类的作用
 */
public class MyRejectPolicy implements RejectedExecutionHandler {
    @Override
    public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
        // 放入 rabbitmq 、数据库等中间件中
        // 然后使用消息队列的延迟队列后面进行处理
    }
}